import org.apache.spark.sql.{DataFrame, SparkSession}

object TestSpark2Hive {
  def main(args: Array[String]): Unit = {

    val sparkSession = SparkSession.builder()
      .config("spark.sql.warehouse.dir","hdfs://192.168.64.5:9000/user/hive/warehouse")
      .appName("x").master("local[*]").enableHiveSupport().getOrCreate()



    sparkSession.sql("drop database test cascade")

    sparkSession.stop()
  }
}
